feat: Add Event Recorder - #3570

#!/bin/bash
set -euo pipefail

ast-grep outline operator-framework-core/src/test/java --items all --type class,function \
  --match 'DefaultEventSinkTest|DefaultEventRecorderTest'

rg -n -C 4 'new DefaultEventSink|\.v1\(\)\.events\(\)|\.resource\(.*\)\.create\(\)' \
  operator-framework-core/src/test/java

#!/bin/bash
set -euo pipefail

printf '%s\n' '--- DefaultEventSink.java ---'
cat -n operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java

printf '%s\n' '--- DefaultEventRecorderTest.java ---'
cat -n operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorderTest.java

printf '%s\n' '--- event source and test files ---'
fd -t f -i 'event' operator-framework-core/src/main operator-framework-core/src/test | sort

printf '%s\n' '--- Mockito/Fabric8 test dependencies and related test patterns ---'
rg -n -C 3 'mockito|MockWebServer|mock server|KubernetesClient|DefaultEventSink|EventSink' \
  operator-framework-core/pom.xml pom.xml operator-framework-core/src/test operator-framework-core/src/main

#!/bin/bash
set -euo pipefail

printf '%s\n' '--- DefaultEventSink.java ---'
sed -n '1,100p' operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java

printf '%s\n' '--- DefaultEventRecorderTest.java ---'
sed -n '1,240p' operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorderTest.java

printf '%s\n' '--- focused test infrastructure ---'
sed -n '55,145p' operator-framework-core/src/test/java/io/javaoperatorsdk/operator/MockKubernetesClient.java
rg -n -C 3 'Mockito|mock\(|verify\(|MockKubernetesClient|MockWebServer' \
  operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/events \
  operator-framework-core/src/test/java/io/javaoperatorsdk/operator/MockKubernetesClient.java \
  operator-framework-core/pom.xml

printf '%s\n' '--- change status ---'
git status --short
git diff --stat -- operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java \
  operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorderTest.java

#!/bin/bash
set -euo pipefail

python3 - <<'PY'
from pathlib import Path

root = Path("operator-framework-core")
sink = root / "src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java"
tests = list((root / "src/test/java").rglob("*EventSink*Test.java"))
recorder_test = root / "src/test/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorderTest.java"
pom = root / "pom.xml"

source = sink.read_text()
recorder = recorder_test.read_text()
pom_text = pom.read_text() if pom.exists() else ""

checks = {
    "sink_exists": sink.exists(),
    "sink_uses_event_namespace": "inNamespace(event.getMetadata().getNamespace())" in source,
    "sink_calls_create": ".resource(event).create()" in source,
    "sink_test_count": len(tests),
    "recorder_injects_collection_consumer": "emitted::add" in recorder,
    "recorder_constructs_default_sink": "new DefaultEventSink" in recorder,
    "mockito_declared_in_core_pom": "mockito" in pom_text.lower(),
}
for key, value in checks.items():
    print(f"{key}={value}")
if tests:
    print("sink_tests=")
    for path in tests:
        print(path)
PY

printf '%s\n' '--- Mockito declarations in module or parent POMs ---'
rg -n -i -C 2 'mockito' --glob 'pom.xml' .

#!/bin/bash
set -euo pipefail

test_file="operator-framework/src/test/java/io/javaoperatorsdk/operator/config/loader/ConfigLoaderTest.java"
rg -n -C 5 \
  'events\.cluster-scoped-namespace|clusterScopedEventNamespace|withClusterScopedEventNamespace' \
  "$test_file"

#!/bin/bash
set -euo pipefail

echo "== Candidate test and source files =="
fd -i 'ConfigLoader|ConfigurationServiceOverrider' operator-framework/src

echo "== ConfigLoader structure =="
ast-grep outline operator-framework/src/main/java/io/javaoperatorsdk/operator/config/loader/ConfigLoader.java

echo "== Relevant symbols across the repository =="
rg -n -C 4 \
  'events\.cluster-scoped-namespace|clusterScopedEventNamespace|withClusterScopedEventNamespace|ConfigBinding|ConfigLoaderTest' \
  operator-framework/src/main operator-framework/src/test

#!/bin/bash
set -euo pipefail

echo "== ConfigLoaderTest outline =="
ast-grep outline operator-framework/src/test/java/io/javaoperatorsdk/operator/config/loader/ConfigLoaderTest.java

echo "== ConfigLoaderTest body =="
cat -n operator-framework/src/test/java/io/javaoperatorsdk/operator/config/loader/ConfigLoaderTest.java

echo "== ConfigurationServiceOverrider files and relevant methods =="
fd -i 'ConfigurationServiceOverrider' operator-framework/src
rg -n -C 5 \
  'withClusterScopedEventNamespace|clusterScopedEventNamespace|applyConfigs|ConfigurationServiceOverrider' \
  operator-framework/src/main operator-framework/src/test

#!/bin/bash
set -euo pipefail

echo "== Configuration API locations =="
fd -i 'ConfigurationService|ConfigurationServiceOverrider' .

echo "== Event namespace symbols across tracked files =="
rg -n -C 6 \
  'withClusterScopedEventNamespace|clusterScopedEventNamespace|cluster-scoped-namespace' \
  -g '*.java' -g '*.xml' .

echo "== Loader application path =="
sed -n '180,225p' operator-framework/src/main/java/io/javaoperatorsdk/operator/config/loader/ConfigLoader.java
sed -n '350,405p' operator-framework/src/main/java/io/javaoperatorsdk/operator/config/loader/ConfigLoader.java

#!/bin/bash
set -euo pipefail

python3 - <<'PY'
def java_hash(value):
    result = 0
    for char in value:
        result = (31 * result + ord(char)) & 0xffffffff
    return result

prefix = "\0".join(["Kind", "uid", "Normal", "Reason", "controller"]) + "\0"
first = prefix + "Aa"
second = prefix + "BB"

assert first != second
assert (java_hash(first) & 0x7fffffff) == (java_hash(second) & 0x7fffffff)
print("Confirmed: distinct event identities collide under String.hashCode().")
PY

#!/bin/bash
set -euo pipefail

printf '%s\n' '--- target file outline ---'
ast-grep outline operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorder.java

printf '%s\n' '--- target implementation ---'
sed -n '120,220p' operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorder.java

printf '%s\n' '--- event sink and event-name usages ---'
rg -n -C 5 'class DefaultEventSink|DefaultEventSink|eventName\(|IDENTITY_SEPARATOR|String\.hashCode|Integer\.toHexString' operator-framework-core operator-framework-*/src/test 2>/dev/null || true

printf '%s\n' '--- relevant test files ---'
git ls-files | rg 'DefaultEventRecorder|DefaultEventSink|EventRecorder|EventSink'

#!/bin/bash
set -euo pipefail

printf '%s\n' '--- DefaultEventSink.java ---'
wc -l operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java
cat -n operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java

printf '%s\n' '--- DefaultEventRecorderTest outline ---'
ast-grep outline operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorderTest.java

printf '%s\n' '--- DefaultEventRecorderTest.java ---'
wc -l operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorderTest.java
cat -n operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorderTest.java

#!/bin/bash
set -euo pipefail

rg -n -C 3 'fabric8|kubernetes-client' --glob 'pom.xml' .
rg -n -C 4 'KubernetesClientException|CONFLICT|409|already exists' \
  operator-framework-core/src/main/java

#!/bin/bash
set -euo pipefail

printf '%s\n' '--- diff ---'
git diff -- operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java \
  operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events \
  operator-framework-core/src/test

printf '%s\n' '--- event source files ---'
git ls-files | rg 'DefaultEvent(Sink|Recorder)|EventSink|EventRecorder|event.*(Test|IT)|Test.*event' | head -120

printf '%s\n' '--- DefaultEventSink ---'
cat -n operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java

printf '%s\n' '--- recorder references and implementation ---'
rg -n -C 8 'class DefaultEventRecorder|DefaultEventRecorder|record\(|eventSink|emit\(' \
  operator-framework-core/src/main/java operator-framework-core/src/test \
  --glob '*.java' | head -300

printf '%s\n' '--- event RBAC references ---'
rg -n -C 3 'events|Event' --glob '*.yaml' --glob '*.yml' --glob '*.java' --glob '*.xml' \
  . | head -300

#!/bin/bash
set -euo pipefail

printf '%s\n' '--- repository state ---'
git status --short
git diff --stat
git diff --cached --stat

printf '%s\n' '--- DefaultEventRecorder implementation ---'
cat -n operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorder.java

printf '%s\n' '--- focused event tests ---'
cat -n operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorderTest.java | sed -n '1,230p'
rg -n -C 5 'DefaultEventSink|new DefaultEventSink|EventSink' \
  operator-framework-core/src/test operator-framework/src/test --glob '*.java' | head -160

printf '%s\n' '--- event permission declarations ---'
rg -n -C 4 '(^|[^[:alnum:]_-])events([^[:alnum:]_-]|$)' \
  --glob '*.yaml' --glob '*.yml' --glob '*.java' --glob '*.md' . \
  | head -240

#!/bin/bash
set -u

printf '%s\n' '--- history and parent ---'
git log --oneline -5 -- operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java
printf 'HEAD: '; git rev-parse HEAD
printf '%s\n' '--- parent DefaultEventSink ---'
if git rev-parse HEAD^ >/dev/null 2>&1; then
  git show HEAD^:operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java 2>&1
fi

printf '%s\n' '--- all permission-related references ---'
rg -n -i -C 3 'events|rbac|role.*verb|verbs:|create.*permission|permission.*create' \
  --glob '*.yaml' --glob '*.yml' --glob '*.java' --glob '*.md' . \
  | head -300 || true

printf '%s\n' '--- sink and mock-server references ---'
rg -n -C 4 'DefaultEventSink|v1\(\)\.events|kubernetes-server-mock|MockWebServer|Authorization' \
  operator-framework-core/src/test operator-framework/src/test --glob '*.java' \
  | head -240 || true

#!/bin/bash
set -euo pipefail

python3 - <<'PY'
from pathlib import Path
import subprocess

current = Path(
    "operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java"
).read_text()
parent = subprocess.check_output(
    [
        "git",
        "show",
        "HEAD^:operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventSink.java",
    ],
    text=True,
)
chart = Path("helm/generic-helm-chart/templates/clusterrole.yaml").read_text()
recorder = Path(
    "operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/events/DefaultEventRecorder.java"
).read_text()

assert ".withName(event.getMetadata().getName()).get()" in current
assert "if (existing == null)" in current
assert ".resource(event).create()" in parent
assert ".withName(event.getMetadata().getName()).get()" not in parent
assert "- events" in chart and "- create" in chart and "- patch" in chart
assert "sink.emit(toEvent(regarding, event));" in recorder
assert "catch (Exception e)" in recorder
print("current sink has preflight GET")
print("parent sink created directly")
print("default Helm event RBAC has create and patch, but no get")
print("recorder catches sink exceptions")
PY